package ttestExecuter;

import station.DataMessage;

public class TestSender implements Runnable {

    private int cnt;
    private SlotExecuter sExec;

    public TestSender() {
        this.cnt = 0;
        this.sExec = SlotExecuter.getInstance();
    }

    public void send(DataMessage msg) {
    	System.out.println("MSG #" + cnt);
        // System.out.println("Send: " + cnt + ". Msg = " +
        // msg.getUserdata()[0]);
        cnt++;
    }

    @Override
    public void run() {
        send(sExec.nextMsg());
    }

}
